package com.test.consumer.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @program: spring-boot-learning
 * @description: 队列配置
 * @author: https://niaobulashi.com
 * @create: 2019-05-09 16:20
 **/
@Configuration
public class RabbitConfig {

    public static final String USER_QUEUE ="user_create";

    @Bean
    public Queue queue(){
        return new Queue(USER_QUEUE,true);
    }

}

